# coding:utf-8

# 与kafka中间件交互的模块处理
from config import envs
import os



topic = ""
bootstrap_servers = ""
kafkaDir = ""
isStart = False

def init_kafka(in_topic="getOperationScore", in_bootstrap_servers="82.156.251.32:9092"):
    global topic, bootstrap_servers, pass_list, isStart
    if isStart:
        return
    topic = in_topic
    bootstrap_servers = in_bootstrap_servers
    isStart = True

def init_logDir(logdir):
    global kafkaDir
    kafkaDir = logdir